Core/[root]/JsWebSocketSession

JsWebSocketSession

internal class JsWebSocketSession(val coroutineContext: CoroutineContext, val websocket: WebSocket) : DefaultWebSocketSession

Constructors

JsWebSocketSession

constructor(coroutineContext: CoroutineContext, websocket: WebSocket)

Properties

_closeReason

private val _closeReason: CompletableDeferred<CloseReason>

_incoming

private val _incoming: Channel<Frame>

_outgoing

private val _outgoing: Channel<Frame>

closeReason

open override val closeReason: Deferred<CloseReason?>

coroutineContext

open override val coroutineContext: CoroutineContext

extensions

open override val extensions: List<WebSocketExtension<*>>

incoming

open override val incoming: ReceiveChannel<Frame>

masking

open override var masking: Boolean

maxFrameSize

open override var maxFrameSize: Long

outgoing

open override val outgoing: SendChannel<Frame>

pingIntervalMillis

open override var pingIntervalMillis: Long

timeoutMillis

open override var timeoutMillis: Long

websocket

private val websocket: WebSocket

Functions

channelFromStream

internal fun CoroutineScope.channelFromStream(stream: ReadableStream<Uint8Array>): ByteReadChannel

flush

open suspend override fun flush()

isReservedStatusCode

private fun Short.isReservedStatusCode(): Boolean

readBody

internal suspend fun CoroutineScope.readBody(response: Response): ByteReadChannel

readBodyBrowser

internal suspend fun CoroutineScope.readBodyBrowser(response: Response): ByteReadChannel

send

open suspend fun send(frame: Frame)

start

open override fun start(negotiatedExtensions: List<WebSocketExtension<*>>)

terminate

open override fun ~~terminate~~()